package net.alan.etl.i;

import net.alan.etl.kafka.FlowParams;

/**
 * @author 李岩飞
 * @email eliyanfei@126.com
 * @date 2018年5月10日下午2:06:52
 */
public interface IFlowTask extends Runnable {
	/**
	 * 是否定时器
	 */
	boolean timer();

	/**
	 * 注册任务ID
	 */
	String taskId();

	/**
	 * 监听ID
	 */
	String monitorTaskId();

	/**
	 * 初始化参数
	 */
	void initParam(FlowParams params);
}
